package com.mxnavi5.example.DataStream;

import org.apache.flink.api.common.functions.ReduceFunction;

public class MyReduceFunction implements ReduceFunction<Integer> {
    @Override
    public Integer reduce(Integer integer, Integer t1) throws Exception {
        return integer+t1;
    }
}
